package spark.hope

import org.apache.spark.sql.SparkSession

object SparkScaner {

  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder().appName("SparkTest")
      .config("hadoop.home.dir", "D:\\Environment\\hadoop-2.7.6")
      .master("local[*]").getOrCreate()

    val df = spark.read.textFile("D:\\home\\logs")
    df.show()
  }
}
